632947856f9195b9e74984facd584f0a41646c7c,spark/src/test/java/org/apache/zeppelin/spark/SparkSqlInterpreterTest.java,SparkSqlInterpreterTest,setUp,#,49
Before Change
p.setProperty("zeppelin.spark.concurrentSQL", "false");
p.setProperty("zeppelin.spark.sql.stacktrace", "false");
if (repl == null) {
if (SparkInterpreterTest.repl == null) {
repl = new SparkInterpreter(p);
intpGroup = new InterpreterGroup();
repl.setInterpreterGroup(intpGroup);
repl.open();
SparkInterpreterTest.repl = repl;
SparkInterpreterTest.intpGroup = intpGroup;
} else {
repl = SparkInterpreterTest.repl;
intpGroup = SparkInterpreterTest.intpGroup;
}
sql = new SparkSqlInterpreter(p);
intpGroup = new InterpreterGroup();
intpGroup.put("note", new LinkedList<Interpreter>());
intpGroup.get("note").add(repl);
intpGroup.get("note").add(sql);
sql.setInterpreterGroup(intpGroup);
sql.open();
}
context = new InterpreterContext("note", "id", null, "title", "text", new AuthenticationInfo(),
After Change
repl = new SparkInterpreter(p);
intpGroup = new InterpreterGroup();
repl.setInterpreterGroup(intpGroup);
repl.open();
SparkInterpreterTest.repl = repl;
SparkInterpreterTest.intpGroup = intpGroup;
sql = new SparkSqlInterpreter(p);
intpGroup = new InterpreterGroup();
intpGroup.put("note", new LinkedList<Interpreter>());
intpGroup.get("note").add(repl);
intpGroup.get("note").add(sql);
sql.setInterpreterGroup(intpGroup);
sql.open();
context = new InterpreterContext("note", "id", null, "title", "text", new AuthenticationInfo(),